package cn.doitedu.day02.partitions

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.3.29
 * @Created by HANGGE
 * @Description
 *             RDD的分区个数
 *   1 从数据源创建的RDD
 *   2 调用转换算子 创建的RDD
 */
object C01_PartitionNumber02 {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc

    // 加载文件查看RDD  --->  并行度  分区数
    // 1) 本地集合
    val rdd1 = sc.makeRDD(Array(1, 2, 3, 4, 5, 6))
    val number1 = rdd1.getNumPartitions
    println(s"rdd1的分区个数 : 并行度为: $number1")
   // 创建RDD的时候指定分区个数
    val rdd2 = sc.makeRDD(List(1, 2, 3, 4, 5), 3)
    val number2 = rdd2.getNumPartitions
    println(s"rdd1的分区个数 : 并行度为: $number2")




  }

}
